package com.example.mq.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.mq.po.SequentialMsgConsumePositionPO;
/*
@description:
@ClassName ISequentialMsgConsumePositionService
@author chen
@create 2025-08-25 19:56
@Version 1.0
*/
public interface ISequentialMsgConsumePositionService extends IService<SequentialMsgConsumePositionPO>
{
    /**
     * 根据 groupId  & queueName 获取记录，不存在的时候则创建
     *
     * @param groupId
     * @param queueName
     * @return
     */
    SequentialMsgConsumePositionPO getAndCreate(String groupId, String queueName);
}
